package zhongbo.java.air.config;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.Topic;
import zhongbo.java.air.listener.RedisSubscribePusChaneIListener;

@Configuration
@Slf4j
public class RedisListenerConfig {

    public static String LIVE_PATH = "live_flight_path_zhang_hong_ying";

    @Autowired
    public void configListener(RedisMessageListenerContainer listenerContainer,
                               RedisSubscribePusChaneIListener PusChaneIListener) {
        log.info("配置redis监听器");

        Topic PusTopic = new PatternTopic(LIVE_PATH);
//        Topic Topic = new PatternTopic(INJEST_CHANNEL);
        listenerContainer.addMessageListener(PusChaneIListener, PusTopic);
//        listenerContainer.addMessageListener(logChaneIListener, Topic);
    }
}
